package com.ng.biz.service;

import com.alibaba.fastjson.JSONObject;
import com.ng.common.model.response.R;

public interface IMqttClient {
	

	public void startDefaultBoot();
	
	public void stopAllBoot();

	R<String> start(String mqttId);

	boolean containsKey(String taskId);

	void stop(String id);

	void executeFlow(String clientId,String topic, JSONObject jsonObject, String payload);

	public void publish(String clientId, String topic, String payload, int qos, boolean retained);
	
	public void incrementAndGet();

	public int getAndSet(int delta);

	public void useSysPublish(String topic, String payload, int qos, boolean retained);

	
	public void sendIncrementAndGet();
	
	public int getSendAndSet(int delta);

}
